#ifndef MSG_QUEUE_H
#define MSG_QUEUE_H

#include <mqueue.h>

#define QUEUE_NAME  "/mcu_command_queue"
#define MAX_MSG_SIZE 1024

// 创建消息队列
mqd_t create_msg_queue();
// 发送消息到队列
void send_to_queue(mqd_t mq, const char* msg);
// 接收队列消息
void receive_from_queue(mqd_t mq, char* buffer);
// 关闭消息队列
void close_msg_queue(mqd_t mq);

#endif